package com.rr.learningdemo.stream.bindings;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author zhuangcanrun
 * @Date 2021/06/16/10:14
 * @description
 **/

public interface MyProcessor{


    String MY_INPUT = "myInput";
    @Input(MY_INPUT)
    SubscribableChannel myInput();

    String MY_OUTPUT = "myOutput";
    @Output(MY_OUTPUT)
    MessageChannel myOutput();
}
